package org.example;

import org.apache.hadoop.fs.FileSystem;
import org.apache.hadoop.fs.Path;

import java.io.IOException;
import java.net.URISyntaxException;

public class HdfsClientCreateFolders {


    public static void main(String[] args) throws URISyntaxException, IOException, InterruptedException {
        Path path = new Path("/user/hive/warehouse");
        try (FileSystem fs = HadoopConnectUtil.getFileSystem()) {
            if (!fs.exists(path)) {
                fs.mkdirs(path);
            }
        }
    }
}